package com.egaleye.mqbus.core.consumer;


import com.egaleye.mqbus.core.exception.MQException;

public interface ConsumerHandler {

    void onHandler(Object obj);

    void onFailure(MQException exception);

}